package com.es.spring_es.rabbitmq.listener;

import com.es.spring_es.rabbitmq.msg.MqMsg;
import com.google.gson.Gson;
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.rabbit.annotation.*;
import org.springframework.amqp.support.AmqpHeaders;
import org.springframework.messaging.handler.annotation.Header;
import org.springframework.messaging.handler.annotation.Headers;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Component;

import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * Created with IntelliJ IDEA
 * User: z
 * DATE: 2019/11/7
 * TIME: 2019-11-07
 * Description:
 */
@Component
public class MyTopicListener {

    public static AtomicInteger atomicInteger = new AtomicInteger(1);



}
